<?php
namespace app\push\controller;
use think\worker\Server;
class HttpWorker extends Server{
	protected $socket = 'http://0.0.0.0:2348';
	/**
	 * 收到信息
	 * @param $connection
	 * @param $data
	 */
	public function onMessage($connection, $data)
	{
		echo "我是http";
		$connection->send('我收到你的信息了');
	}
	/**
	 * 当连接建立时触发的回调函数
	 * @param $connection
	 */
	public function onConnect($connection)
	{
		file_put_contents('worker11.txt',$connection);
	}
	/**
	 * 当连接断开时触发的回调函数
	 * @param $connection
	 */
	public function onClose($connection)
	{

	}    /**
 * 当客户端的连接上发生错误时触发
 * @param $connection
 * @param $code
 * @param $msg
 */
	public function onError($connection, $code, $msg)
	{
		echo "error $code $msg\n";
	}
	/**
	 * 每个进程启动
	 * @param $worker
	 */
	public function onWorkerStart($worker)
	{

	}
}
